package com.travelsky.flash.util.msg;

import java.net.URI;

import org.apache.log4j.Logger;

/**
 * @Description 推送消息
 * @author syuan
 * @date 2015年6月2日 上午9:37:55 Company: TravelSky
 */
public class SendMsgUtil {

	private static Logger logger = Logger.getLogger(SendMsgUtil.class);

	private static WebSocketClient clientEndPoint;

	/**
	 * @Description 连接ws服务器
	 * @author syuan
	 * @date 2015年6月2日  上午9:51:59
	 */
	private static void connectWS() {
		if(null == clientEndPoint) {
			// 连接websocket
			try {
				clientEndPoint = new WebSocketClient(new URI("ws://172.22.12.229:8480/flash/msgServer"));
//				clientEndPoint = new WebSocketClient(new URI("ws://localhost:8080/flash/msgServer"));
			} catch (Exception e) {
				logger.error("", e);
			}
			// 消息处理
			clientEndPoint.addMessageHandler(new WebSocketClient.MessageHandler() {
				public void handleMessage(String message) {
					// 新消息不做处理
				}
			});
		}

	}
	
	/**
	 * @Description 发送消息
	 * @param msg
	 * @author syuan
	 * @date 2015年6月2日  上午9:48:30
	 */
	public static void sendMsg(String msg) {
		connectWS();
		clientEndPoint.sendMessage(msg);
	}
}
